//引入mysql包：
const mysql = require('mysql');

//创建mysql连接：
let mysqlObj = mysql.createConnection({
    host: 'localhost',
    port: 3306,
    user: 'root',
    password: 'root',
    database: 'xiaou'
});

//连接mysql数据库：
mysqlObj.connect();

function execSql(sql) {
    return new Promise((resolved, rejected) => {
        mysqlObj.query(sql, (err, result) => {

            // console.log(err, result);
            //需求：返回err及result
            if (err) { //失败
                // rejected('sql执行失败，请重试');
                resolved([false, 'sql执行失败，请重试']);
            } else { //成功
                resolved([true, result]);
            }

        });

    });
}

//暴露execSql方法
module.exports = execSql;